package com.bee.plus.market.service;

import com.bee.plus.vo.ChatMessageVo;
import com.bee.plus.vo.ChatResponseVo;
import io.reactivex.Flowable;
import reactor.core.publisher.Flux;

/**
 * @author xupei
 */
public interface MarketAiService {

    /**
     * 单轮会话
     * @param chatMessageVo
     * @return
     */
    public ChatResponseVo chat(ChatMessageVo chatMessageVo);


    public Flowable<ChatResponseVo> chatStream(ChatMessageVo chatMessageVo);


    public void storeChatMessage(ChatResponseVo responseVo);

}
